package com.linjing.demo.message.mq;

import org.apache.rocketmq.client.exception.MQClientException;

/**
 * @name: MQConsumerTest
 * @Author: wangshimin
 * @Date: 2019/10/31  15:32
 * @Description:
 */
public class MQConsumerTest {
    public static void main(String[] args) throws MQClientException {
       MQConsumer mqConsumer=new MQConsumer();
       mqConsumer.init();
    }
}
